package drds.data_propagate.instance.manager;

import drds.data_propagate.instance.manager.model.Task;

/**
 * 对应canal的配置
 */
public class TaskManager {

    /**
     * 根据对应的destinantion查询Canal信息
     */
    public Task findTask(String destination) {
        // TODO 根据自己的业务实现
        throw new UnsupportedOperationException();
    }

    /**
     * 根据对应的destinantion查询filter信息
     */
    public String findFilter(String destination) {
        // TODO 根据自己的业务实现
        throw new UnsupportedOperationException();
    }

}
